package com.lefeng.cockpit.datax.dao;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.lefeng.cockpit.common.bean.dto.datasource.DataSourceDTO;
import com.lefeng.cockpit.common.bean.po.datasource.DataSourcePO;
import com.lefeng.cockpit.common.bean.po.datasource.JobRegistryPO;

import java.util.Date;
import java.util.List;

/**
 * @author weifw
 */
public interface JobRegistryDao {

    int registryUpdate(JobRegistryPO jobRegistryPO);

    int registrySave(JobRegistryPO jobRegistryPO);

    int registryDelete(JobRegistryPO jobRegistryPO);

    List<JobRegistryPO> findAll(int deadTimeout, Date date);

    List<Integer> findDead(int deadTimeout, Date date);

    void removeDead(List<Integer> ids);
}
